4bbdeddb37d91dc82ba8865f864020937e6e1e2a,epcis-capture/src/main/java/org/oliot/epcis/serde/mongodb/AggregationEventWriteConverter.java,AggregationEventWriteConverter,convert,#AggregationEventType#number#,42
Before Change
BsonDocument dbo = new BsonDocument();
// Base Extension
if (aggregationEventType.getBaseExtension() != null) {
EPCISEventExtensionType baseExtensionType = aggregationEventType.getBaseExtension();
BsonDocument baseExtension = getBaseExtensionObject(baseExtensionType);
dbo.put("baseExtension", baseExtension);
}
// Event Time
if (aggregationEventType.getEventTime() != null)
After Change
// Event ID
if (aggregationEventType.getBaseExtension() != null) {
if (aggregationEventType.getBaseExtension().getEventID() != null) {
dbo.put("eventID", new BsonString(aggregationEventType.getBaseExtension().getEventID()));
}
}
// Error Declaration
// If declared, it notes that the event is erroneous
if (aggregationEventType.getBaseExtension() != null) {
EPCISEventExtensionType eeet = aggregationEventType.getBaseExtension();
ErrorDeclarationType edt = eeet.getErrorDeclaration();
if (edt != null) {
if (edt.getDeclarationTime() != null) {
dbo.put("errorDeclaration", MongoWriterUtil.getErrorDeclaration(edt));
}
}
}